package Repositorio;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import Dados.Administrador;

public class RepositorioAdministrador {
	private Statement stmt;
	private String sqlStatement;
	public RepositorioAdministrador() {
		stmt = Conexao.getInstance().stmt;
	}
	public void cadastrarAdministrador(Administrador adm) throws SQLException {
		RepositorioUsuario repUsuario = new RepositorioUsuario();
		if(!repUsuario.verificarUsuario(adm.getCpf())) {
			repUsuario.cadastrarUsuario(adm);
		}
		sqlStatement = "INSERT INTO Administrador VALUES('"+adm.getCpf()+"')";
		stmt.executeUpdate(sqlStatement);
	}
	public void editarAdministrador(Administrador adm) throws SQLException {
		RepositorioUsuario repUsuario = new RepositorioUsuario();
		repUsuario.editarUsuario(adm);
	}
	public void removerAdministrador(String cpf) throws SQLException {
		RepositorioUsuario repUsuario = new RepositorioUsuario();
		sqlStatement = "DELETE FROM Administrador WHERE cpf='"+cpf+"'";
		stmt.executeUpdate(sqlStatement);
		repUsuario.removerUsuario(cpf);
	}
	public Administrador consultarAdministrador(String cpf) throws SQLException {
		RepositorioUsuario repUsuario = new RepositorioUsuario();
		Administrador admin = new Administrador(repUsuario.consultarUsuario(cpf));
		return admin;
	}
	public boolean verificarAdministrador(String cpf) throws SQLException {
		boolean ret;
		sqlStatement = "SELECT * FROM Administrador WHERE cpf='"+cpf+"'";
		ResultSet rs = stmt.executeQuery(sqlStatement);
		if(rs.next()) {
			ret = true;
		} else {
			ret = false;
		}
		return ret;
	}
};
